package hook

import (
	"time"

	"gitee.com/xgotool/backend-framework-template/service/progress"
)

// 进度条清理进程
//
//	hook.progress.clean	<nil>
func ProgressClean(param []byte) error {
	lis := progress.List()
	for i := 0; i < len(lis); i++ {
		if lis[i].EndTime > 0 {
			// 任务已结束
			if lis[i].EndTime < time.Now().Unix()-60*5 {
				// 任务已超时5分钟，进行清理
				progress.Remove(lis[i].Key)
			}
		}
	}
	return nil
}
